package com.demo.simple;

import reactor.core.publisher.Mono;
import reactor.netty.DisposableServer;
import reactor.netty.tcp.TcpServer;

public class ServerDemo {

	public static void main(String[] args) {
		DisposableServer server =
                TcpServer.create()
                         .host("localhost")
                         .port(8080)
                         // 为了将数据发送到连接的客户端，您必须附加一个I / O处理程序。I / O处理程序有权访问NettyOutbound 数据。以下示例显示了如何附加I / O处理程序
                         .handle((inbound, outbound) -> outbound.sendString(Mono.just("server: hello")))
                         // 为了从连接的客户端接收数据，您必须附加一个I / O处理程序。I / O处理程序有权访问NettyInbound 数据。以下示例显示了如何使用它
                         .handle((inbound, outbound) -> inbound.receive().then())
                         .bindNow();

        server.onDispose()
              .block();
	}

}
